package pers.vic.mq.kafka.listener;

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.kafka.listener.MessageListener;

@Deprecated
public class KafkaConsumerListener implements MessageListener<Integer, String> {

	private Logger logger = LoggerFactory.getLogger(getClass());

    public void onMessage(ConsumerRecord<Integer, String> consumerRecord) {
    	logger .info("----into------KafkaConsumerListener-------------");	
        Object o = consumerRecord.value();
        System.out.println(String.valueOf(o));
    }
}
